package org.itstack.demo.design.util;

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

/**
 * @Author: fanYuLe
 * @CreateTime: 2023-12-25  15:44
 * @Description:
 */
public class RedisUtil {
    private ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
    private AtomicInteger stock = new AtomicInteger(0);

    public RedisUtil(){
        scheduledExecutorService.scheduleAtFixedRate(()->{
            //模拟库存消耗
            stock.addAndGet(1);
        },0,100000, TimeUnit.MICROSECONDS);
    }

    public int getStockUsed(){return stock.get();}
}
